package com.inventive.jmscache.server;

import javax.jms.*;

/**
 * @author Grant Little <grant.little@coreservices.com.au>
 */
public class JmsCacheQueueConnection extends JmsCacheConnection implements QueueConnection {

    public JmsCacheQueueConnection(JmsCacheServer jmsCacheServer) {
        super(jmsCacheServer);
    }

    public QueueSession createQueueSession(boolean transacted, int acknowledgeMode) throws JMSException {
        return new JmsCacheQueueSession(jmsCacheServer, transacted, acknowledgeMode);
    }

    public ConnectionConsumer createConnectionConsumer(Queue queue, String s, ServerSessionPool serverSessionPool, int i) throws JMSException {
        checkClosed();
        return null;
    }

}
